package com.xiao.dynamic_rule.service;

import com.xiao.dynamic_rule.pojo.LogBean;
import com.xiao.dynamic_rule.pojo.RuleParam;
import com.xiao.dynamic_rule.pojo.RuleParamAtomic;
import org.apache.flink.api.common.state.ListState;

/**
 * 用户行为次数类条件查询接口
 */
public interface UserActionCountQueryService {
    boolean queryActionCounts(String deviceId,ListState<LogBean> eventState, RuleParam ruleParam) throws Exception;
    boolean queryActionCount(String deviceId,ListState<LogBean> eventState, RuleParamAtomic atomicParam) throws Exception;
}
